package springboot.kafka.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 * @author cm
 * @version 1.0
 * @date 2022/5/27 15:42
 */
@TableName("kafka_offset")
@Data
public class KafkaOffset {

    @TableField(value = "topic")
    private String topic;

    // 分组
    @TableField(value = "consumer_group")
    private String consumerGroup;

    // 分区
    @TableField(value = "consumer_partition")
    private String consumerPartition;

    // 偏移量
    @TableField(value = "consumer_offset")
    private String consumerOffset;

    // 创建时间
    @TableField(value = "create_time")
    private Date createTime;

}
